#doris网点基础资料表
create database jms_dim;
drop table IF EXISTS jms_dim.dim_sys_network_detail;
CREATE TABLE IF NOT EXISTS jms_dim.dim_sys_network_detail (
`id` bigint(20) COMMENT '主键id',
`name` varchar(500) COMMENT '名称',
`code` varchar(500) COMMENT '编号',
`signature_code` varchar(500) COMMENT '特征码',
`cn_name` varchar(500) COMMENT '中文名称',
`en_name` varchar(500) COMMENT '英文名称',
`country_id` bigint(20) COMMENT '所属国家',
`country_code` varchar(500) COMMENT '所属国家编码',
`country_desc` varchar(500) COMMENT '所属国家名称',
`country_three_code` varchar(500) COMMENT '所属国家三字码',
`regional_id` bigint(20) COMMENT '大区ID',
`regional_desc` varchar(500) COMMENT '大区名称',
`area_info_id` bigint(20) COMMENT '片区ID',
`area_info_desc` varchar(500) COMMENT '片区名称',
`provider_id` bigint(20) COMMENT '省份ID',
`provider_desc` varchar(500) COMMENT '省份',
`city_id` bigint(20) COMMENT '城市ID',
`city_desc` varchar(500) COMMENT '城市',
`area_id` bigint(20) COMMENT '区/县ID',
`area_desc` varchar(500) COMMENT '区/县',
`township_id` bigint(20) COMMENT '乡镇ID',
`principal` varchar(500) COMMENT '负责人',
`mobile` varchar(500) COMMENT '手机号码',
`telephone` varchar(500) COMMENT '座机号',
`parent_network_id` bigint(20) COMMENT '所属网点ID',
`parent_network_code` varchar(500) COMMENT '所属网点编码',
`parent_network_name` varchar(500) COMMENT '所属网点名称',
`financial_center_id` bigint(20) COMMENT '财务中心ID',
`financial_center_code` varchar(500) COMMENT '财务中心code',
`financial_center_desc` varchar(500) COMMENT '财务中心名称',
`function_type_id` tinyint(4) COMMENT '功能类型ID',
`function_type_desc` varchar(500) COMMENT '功能类型描述',
`type_id` tinyint(4) COMMENT '网点类型ID',
`type_desc` varchar(500) COMMENT '网点类型描述',
`institutional_level_id` tinyint(4) COMMENT '机构级别',
`institutional_level_desc` varchar(500) COMMENT '机构级别描述',
`max_collection_money` bigint(20) COMMENT '代收货款上限',
`settlement_destination_id` bigint(20) COMMENT '结算目的地ID',
`settlement_destination_desc` varchar(500) COMMENT '结算目的地描述',
`is_collection_identifier` tinyint(4) COMMENT '代收货款标识:1是,2否',
`is_distribution_center` tinyint(4) COMMENT '是否分拨中心标识:1是,2否',
`business_model_id` tinyint(4) COMMENT '经营方式',
`business_model_desc` varchar(500) COMMENT '经营方式描述',
`local_currency_id` tinyint(4) COMMENT '本币币别',
`local_currency_code` varchar(500) COMMENT '本币币别编码',
`local_currency_desc` varchar(500) COMMENT '本币币别描述',
`is_financial_center` tinyint(4) COMMENT '财务中心标识:1是,2否',
`is_waybill_identification` tinyint(4) COMMENT '运单发放标识:1是,2否',
`is_to_payment` tinyint(4) COMMENT '到付款标识:1是,2否',
`is_visibility` tinyint(4) COMMENT '是否对外显示 1是 2否',
`is_enable` tinyint(4) COMMENT '是否启用:0待启用,1启用,2不启用',
`is_leaf` tinyint(4) COMMENT '是否叶子节点:1是,2否',
`is_delete` tinyint(4) COMMENT '是否删除:1未删除,2已删除',
`address` varchar(500) COMMENT '详细地址',
`business_principal` varchar(500) COMMENT '业务负责人',
`business_telephone` varchar(500) COMMENT '业务电话',
`customer_service_principal` varchar(500) COMMENT '客服负责人',
`customer_service_telephone` varchar(500) COMMENT '客服电话',
`longitude` varchar(500) COMMENT '经度',
`latitude` varchar(500) COMMENT '纬度',
`create_by` bigint(20) COMMENT '创建人ID',
`update_by` bigint(20) COMMENT '最后更新人ID',
`create_by_name` varchar(500) COMMENT '创建人名称',
`update_by_name` varchar(500) COMMENT '最后修改人名称',
`create_time` datetime COMMENT '创建时间',
`update_time` datetime COMMENT '更新时间',
`version` varchar(500) COMMENT '版本号',
`sort` bigint(20) COMMENT '排序',
`remark` varchar(500) COMMENT '',
`path` varchar(500) COMMENT '树路径',
`is_receiving` bigint(20) COMMENT '是否有收货电子围栏:1是,2否',
`is_dispatch` bigint(20) COMMENT '是否有派货电子围栏:1是,2否',
`zip_code` varchar(500) COMMENT '邮编',
`start_business_time` datetime COMMENT '开始营业时间',
`end_business_time` datetime COMMENT '结束营业时间',
`last_update_time_sync` datetime COMMENT '同步时间戳-',
`coordinate` varchar(500) COMMENT '网点经纬度',
`subordinate_agent` varchar(500) COMMENT '所属代理',
`is_first_network_settle` tinyint(4) COMMENT '是否一级网点结算标识,1:是,2:否',
`simple_name` varchar(500) COMMENT '简称',
`is_first_franchisee` tinyint(4) COMMENT '是否一级加盟商 1是 2否',
`is_second_franchisee` tinyint(4) COMMENT '是否二级加盟商 1是 2否',
`is_entrepot` tinyint(4) COMMENT '是否集散',
`to_payment_limit` bigint(20) COMMENT '到付款限额',
`opening_type` tinyint(4) COMMENT '开通类型:1-新开通 2-合并开通 3-转让开通，4-拆分开通',
`opening_time` datetime COMMENT '开通时间',
`is_retrogression` tinyint(4) COMMENT '是否退转网点 1是 2否 默认（2-否）',
`is_suspend` tinyint(4) COMMENT '是否暂停(1是,2否)默认2-否',
`leaving_time` datetime COMMENT '暂停时间',
`agent_id` bigint(20) COMMENT '代理区id',
`agent_code` varchar(500) COMMENT '代理区cdoe',
`agent_name` varchar(500) COMMENT '代理区名称',
`franchisee_id` bigint(20) COMMENT '加盟商id',
`franchisee_code` varchar(500) COMMENT '加盟商code',
`franchisee_name` varchar(500) COMMENT '加盟商名称',
`transcenter_id` bigint(20) COMMENT '转运中心id',
`transcenter_code` varchar(500) COMMENT '转运中心code',
`transcenter_name` varchar(500) COMMENT '转运中心名称'
) ENGINE = OLAP
UNIQUE KEY(`id`) COMMENT "网点资料功能加强表"
DISTRIBUTED BY HASH(`id`) BUCKETS 3
PROPERTIES (
"replication_num" = "3",
"in_memory" = "true",
"storage_format" = "v2"
);


#hive同步到doris语句  备注：测试使用s07 生产使用Broker1

LOAD LABEL dim_sys_network_detail_dt001
(
    DATA INFILE("hdfs://10.33.50.104:8020/dw/hive/jms_dim.db/external/dim_sys_network_detail_dt/dt=2021-05-07/*")
    INTO TABLE dim_sys_network_detail
    COLUMNS TERMINATED BY "\\x01"
)
WITH BROKER "broker1"
(
    "username"="root",
    "password"="123456"
)
PROPERTIES
(
    "timeout"="36000",
    "exec_mem_limit"="2147483648",
    "max_filter_ratio"="0.0"
);

#查看doris是否同步成功
show load order by createtime desc limit 1